package com.wsb.boot.receiver;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.io.IOException;

/**
 * @author wang shaobo
 * @date 2020/7/17  20:20
 */
@Component
public class LinsterConsumer {

//    @RabbitHandler
//    @RabbitListener(queues = "first-queue-one")
    public void onLogMessage(String logJson) throws IOException{
        System.out.println("进入消费first-queue-one");

        System.out.println("消费消息:"+logJson);


    }

}
